d609df075ed372fb0d9c4b123c42aef28515506c,joker-engine/src/main/java/cs/bilkent/joker/engine/region/impl/PipelineTransformerImpl.java,PipelineTransformerImpl,duplicateMergedPipeline,#number#number#OperatorReplica[]#number#PipelineReplicaId#PipelineReplica#boolean#,227
Before Change
{
final OperatorReplica operator = pipelineReplica.getOperator( i );
final Supplier<TuplesImpl> outputSupplier = ( ( i == ( j - 1 ) ) && isLastMergedPipeline )
? new NonCachedTuplesImplSupplier( operator.getOperatorDef().inputPortCount() )
: new CachedTuplesImplSupplier( operator.getOperatorDef().inputPortCount() );
newOperatorReplicas[ operatorIndex++ ] = operator.duplicate( newPipelineReplicaId,
operator.getQueue(),
After Change
for ( int i = 1, j = pipelineReplica.getOperatorCount(); i < j; i++ )
{
final OperatorReplica operator = pipelineReplica.getOperator( i );
final Supplier<TuplesImpl> outputSupplier = ( ( i == ( j - 1 ) ) && isLastMergedPipeline ) ? OutputSupplierUtils.newInstance(
lastOperatorOutputSupplierClass,
operator.getOperatorDef().inputPortCount() )
: new CachedTuplesImplSupplier( operator.getOperatorDef().inputPortCount() );
newOperatorReplicas[ operatorIndex++ ] = operator.duplicate( newPipelineReplicaId,
operator.getQueue(),